package com.zsy.filink.basic;

import org.apache.commons.lang3.StringUtils;
import org.apache.flink.api.common.functions.FilterFunction;

/**
 * @Author: Zhou ShiYang
 * @Description:
 * @Date:Create：in 2021/7/29 0:05
 **/
public class PKFilterFunction implements FilterFunction<String> {
    @Override
    public boolean filter(String s) throws Exception {
        return StringUtils.isNotEmpty(s);
    }
}
